package com.arica.project.mq.message;

import com.alibaba.fastjson.JSONObject;
import com.arica.project.mq.domain.TestDTO;
import org.apache.rocketmq.common.message.Message;

public class TestMessage extends Message {

    private static final String TEST_TOPIC = "topic_syn";
    private static final String TEST_TAG = "tag_syn";

    public TestMessage(TestDTO messageBody) {
        super(TEST_TOPIC, TEST_TAG, JSONObject.toJSONString(messageBody).getBytes());
    }
}
